Node / meshtastic / Meshtastic-Android / files / core / data / src / commonTest / kotlin / org / meshtastic / core / data / datasource / SwitchingChannelSetDataSourceTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.datasource

Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi

Tff7b72import T7ee787kotlinx.coroutines.async

Tff7b72import T7ee787kotlinx.coroutines.awaitAll

Tff7b72import T7ee787kotlinx.coroutines.coroutineScope

Tff7b72import T7ee787kotlinx.coroutines.flow.first

Tff7b72import T7ee787kotlinx.coroutines.test.UnconfinedTestDispatcher

Tff7b72import T7ee787kotlinx.coroutines.test.runTest

Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers

Tff7b72import T7ee787org.meshtastic.core.testing.FakeDatabaseProvider

Tff7b72import T7ee787org.meshtastic.proto.Channel

Tff7b72import T7ee787org.meshtastic.proto.ChannelSettings

Tff7b72import T7ee787org.meshtastic.proto.Config

Tff7b72import T7ee787kotlin.test.AfterTest

Tff7b72import T7ee787kotlin.test.Test

Tff7b72import T7ee787kotlin.test.assertEquals

Tff7b72import T7ee787kotlin.test.assertTrue

Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4)

Tff7b72class T56d364SwitchingChannelSetDataSourceTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3UnconfinedTestDispatcherTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3dispatchers Tff7b72= Te6edf3CoroutineDispatchersTb4b4b4(Te6edf3main Tff7b72= Te6edf3testDispatcherTb4b4b4, Te6edf3io Tff7b72= Te6edf3testDispatcherTb4b4b4, Te6edf3default Tff7b72= Te6edf3testDispatcherTb4b4b4)

Tff7b72private Tff7b72val Te6edf3dbProvider Tff7b72= Te6edf3FakeDatabaseProviderTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3dataSource Tff7b72= Te6edf3SwitchingChannelSetDataSourceTb4b4b4(Te6edf3dbProviderTb4b4b4, Te6edf3dispatchersTb4b4b4)

Tf0883e@AfterTest Tff7b72fun Td2a8fftearDownTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3dbProviderTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffsecondaryTb4b4b4(Te6edf3indexTb4b4b4: Tffa657IntTb4b4b4, Te6edf3nameTb4b4b4: Tffa657StringTb4b4b4) Tff7b72=

Te6edf3ChannelTb4b4b4(Te6edf3index Tff7b72= Te6edf3indexTb4b4b4, Te6edf3settings Tff7b72= Te6edf3ChannelSettingsTb4b4b4(Te6edf3name Tff7b72= Te6edf3nameTb4b4b4)Tb4b4b4, Te6edf3role Tff7b72= Te6edf3ChannelTb4b4b4.Te6edf3RoleTb4b4b4.Te6edf3SECONDARYTb4b4b4)

Tf0883e@Test

Tff7b72fun Td2a8ff`updateChannelSettings places channel at its index`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(T79c0ff0Tb4b4b4, Ta5d6ff"Ta5d6ffprimaryTa5d6ff"Tb4b4b4)Tb4b4b4)

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(T79c0ff1Tb4b4b4, Ta5d6ff"Ta5d6ffsecondTa5d6ff"Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3names Tff7b72= Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3name Tb4b4b4}

Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Ta5d6ff"Ta5d6ffprimaryTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffsecondTa5d6ff"Tb4b4b4)Tb4b4b4, Te6edf3namesTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`updateChannelSettings fills gaps with blank channels to preserve indices`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

T8b949e// Arrive out of order / with a gap: index 2 before 0/1 exist.

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6ffthirdTa5d6ff"Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3settings Tff7b72= Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settings

Te6edf3assertEqualsTb4b4b4(T79c0ff3Tb4b4b4, Te6edf3settingsTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3settingsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3nameTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3settingsTff7b72[T79c0ff1Tff7b72]Tb4b4b4.Te6edf3nameTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffthirdTa5d6ff"Tb4b4b4, Te6edf3settingsTff7b72[T79c0ff2Tff7b72]Tb4b4b4.Te6edf3nameTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`disabled channels are ignored`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3ChannelTb4b4b4(Te6edf3index Tff7b72= T79c0ff0Tb4b4b4, Te6edf3role Tff7b72= Te6edf3ChannelTb4b4b4.Te6edf3RoleTb4b4b4.Te6edf3DISABLEDTb4b4b4)Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`replaceAllSettings replaces the whole list`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(T79c0ff0Tb4b4b4, Ta5d6ff"Ta5d6ffoldTa5d6ff"Tb4b4b4)Tb4b4b4)

Te6edf3dataSourceTb4b4b4.Te6edf3replaceAllSettingsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3ChannelSettingsTb4b4b4(Te6edf3name Tff7b72= Ta5d6ff"Ta5d6ffaTa5d6ff"Tb4b4b4)Tb4b4b4, Te6edf3ChannelSettingsTb4b4b4(Te6edf3name Tff7b72= Ta5d6ff"Ta5d6ffbTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Ta5d6ff"Ta5d6ffaTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffbTa5d6ff"Tb4b4b4)Tb4b4b4, Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3name Tb4b4b4}Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`setLoraConfig preserves existing channel settings`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(T79c0ff0Tb4b4b4, Ta5d6ff"Ta5d6ffkeepTa5d6ff"Tb4b4b4)Tb4b4b4)

Te6edf3dataSourceTb4b4b4.Te6edf3setLoraConfigTb4b4b4(Te6edf3ConfigTb4b4b4.Te6edf3LoRaConfigTb4b4b4(Te6edf3channel_num Tff7b72= T79c0ff7Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3set Tff7b72= Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffkeepTa5d6ff"Tb4b4b4, Tff7b72setTb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3singleTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3nameTb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff7Tb4b4b4, Tff7b72setTb4b4b4.Te6edf3lora_configTff7b72?.Te6edf3channel_numTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`clearChannelSet empties the channel set`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(T79c0ff0Tb4b4b4, Ta5d6ff"Ta5d6ffgoneTa5d6ff"Tb4b4b4)Tb4b4b4)

Te6edf3dataSourceTb4b4b4.Te6edf3clearChannelSetTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

T8b949e/**

* Regression for #4623: channels are now stored per-device. Switching to a different device's database must NOT

* surface the previous device's channels — the old global DataStore was the source of the cross-device duplicate

* channel rows.

*/

Tf0883e@Test

Tff7b72fun Td2a8ff`switching device does not leak channels across databases`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(T79c0ff0Tb4b4b4, Ta5d6ff"Ta5d6ffdeviceA-primaryTa5d6ff"Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffdeviceA-primaryTa5d6ff"Tb4b4b4, Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3singleTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3nameTb4b4b4)

Te6edf3dbProviderTb4b4b4.Te6edf3switchToNewDatabaseTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(

Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settingsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffA freshly selected device must start with no channels, not device A'sTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

T8b949e/** Handshake fires overlapping updateChannelSettings as it streams channels; the mutex must not drop any. */

Tf0883e@Test

Tff7b72fun Td2a8ff`concurrent updateChannelSettings does not lose updates`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3n Tff7b72= T79c0ff8

Te6edf3coroutineScope Tb4b4b4{

Tb4b4b4(T79c0ff0 Te6edf3until Te6edf3nTb4b4b4)Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3i Tff7b72-Tff7b72> Te6edf3async Tb4b4b4{ Te6edf3dataSourceTb4b4b4.Te6edf3updateChannelSettingsTb4b4b4(Te6edf3secondaryTb4b4b4(Te6edf3iTb4b4b4, Ta5d6ff"Ta5d6ffchTffd700$Te6edf3iTa5d6ff"Tb4b4b4)Tb4b4b4) Tb4b4b4} Tb4b4b4}Tb4b4b4.Te6edf3awaitAllTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72val Te6edf3settings Tff7b72= Te6edf3dataSourceTb4b4b4.Te6edf3channelSetFlowTb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3settings

Te6edf3assertEqualsTb4b4b4(Te6edf3nTb4b4b4, Te6edf3settingsTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Tb4b4b4(T79c0ff0 Te6edf3until Te6edf3nTb4b4b4)Tb4b4b4.Te6edf3map Tb4b4b4{ Ta5d6ff"Ta5d6ffchTffd700$Te6edf3itTa5d6ff" Tb4b4b4}Tb4b4b4, Te6edf3settingsTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3name Tb4b4b4}Tb4b4b4)

Tb4b4b4}

Tb4b4b4}